package com.ww.cheappliers.receive;

import com.ww.cheappliers.Message;
import com.ww.cheappliers.consumer.MessageConsumer;

/**
 * 消息接受者
 * @author tengHy
 *
 */
public interface MessageReaper {
	/**
	 * 收消息的方法 子类实现
	 * 会被while（true）的方式循环调用
	 * 如果定时查消息 那么需要在方法内加上类似sleep这样的语句
	 * @return
	 */
	public Message[] extractMessage();
	
	/**
	 * 消息消费者
	 * @param c
	 */
	public void addConsumer(MessageConsumer c);
	
	/**
	 * 开始接收消息循环
	 */
	public void start();
}
